cb5794491ade6f5fb076201cc79f72a57cae4eed,server/src/test/java/timely/store/iterators/TimeSeriesGroupingIteratorTest.java,TimeSeriesGroupingIteratorTest,testAdditionalTimeSeries,#,165

Before Change


            iter.next();
            if (i > 54) {
                assertTrue(iter.hasTop());
                double expected2 = expectedMovingAverage(new double[] { (i - 4) * 2, (i - 3) * 2, (i - 2) * 2,
                        (i - 1) * 2, i * 2 });
                assertEquals(expected2, MetricAdapter.decodeValue(iter.getTopValue().get()), 0.0D);
                iter.next();
            }
        }
        assertFalse(iter.hasTop());

After Change


            }
        }
        SortedMapIterator source = new SortedMapIterator(table);
        TimeSeriesGroupingIterator iter = new TimeSeriesGroupingIterator();
        IteratorSetting settings = new IteratorSetting(100, TimeSeriesGroupingIterator.class);
        settings.addOption(TimeSeriesGroupingIterator.FILTER, "0.20,0.20,0.20,0.20,0.20");
        iter.init(source, settings.getOptions(), SCAN_IE);
        iter.seek(new Range(), EMPTY_COL_FAMS, true);

        for (int i = 4; i < 100; i++) {
            checkNextResult(iter, new double[] { i - 4, i - 3, i - 2, i - 1, i });
            if (i > 54) {
                checkNextResult(iter, new double[] { (i - 4) * 2, (i - 3) * 2, (i - 2) * 2, (i - 1) * 2, i * 2 });
            }
        }
        assertFalse(iter.hasTop());